package org.example.partition;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class PartitionCustomDemo {
    public static void main(String[] args) throws Exception {
//        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
//        env.fromElements(1,2,3,4,5,6,7,8)
//                .partitionCustom(new MyPartitioner(),x->x)
//                .map(x->x).setParallelism(2).rescale()
//                .print().setParallelism(4);
//        env.execute();
    }
    }
